package nsq;
import java.util.concurrent.TimeoutException;

import com.github.brainlag.nsq.NSQProducer;
import com.github.brainlag.nsq.exceptions.NSQException;

public class Producer {
	public static void main(String[] args) throws NSQException, TimeoutException {
		System.out.println("ok");
		NSQProducer producer = new NSQProducer().addAddress("localhost", 4150).start();            
		producer.produce("test", ("链上星沙").getBytes());
		//producer.shutdown();		
	}
}
